package com.egaleye.mqbus.core.annotation;

import java.lang.annotation.*;

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Consumer {

    String topic();

    //MessageModel model() default MessageModel.QUEUE;

    String msgDataType() default "java.lang.String";

    String queueName() default "";

    String[] routeKeys() default {};

    int instances() default 1;

    boolean queueDuration() default true;

    boolean enableDLX() default true;

}
